//package com.bsj.media.init.websocket;
//
//import com.bsj.media.init.AudioSessionUntil;
//import com.bsj.media.init.NettyIntercomUntil;
//import com.bsj.power.common.def.protocol.rtp.RTPInfo;
//import lombok.extern.slf4j.Slf4j;
//import org.apache.commons.lang3.StringUtils;
//import org.yeauty.pojo.Session;
//
//import java.util.Map;
//import java.util.concurrent.ConcurrentHashMap;
//
//@Slf4j
//public class AudioDataSessionHandle {
//
//    private static Map<String, AudioSessionUntil> sessionAudioDtoMap = new ConcurrentHashMap<>();
//
//    //具有唯一性
//    public static void addData(String terminalNo, Session session) {
//        AudioSessionUntil sessionAudioDto = new AudioSessionUntil(session);
//        String terminalNoNow = terminalNo;
//        //与设备传过来的保持一致
//        if (terminalNo.length() == 11) {
//            terminalNoNow = "0" + terminalNo;
//        }
//        sessionAudioDto.start(terminalNo + "-36");
//        sessionAudioDtoMap.put(terminalNoNow, sessionAudioDto);
//    }
//
//    public static AudioSessionUntil gain(String terminalNo) {
//        return sessionAudioDtoMap.get(terminalNo);
//    }
//
//    public static void pushData(RTPInfo rtpInfo, String terminalNo) {
//        AudioSessionUntil audioSessionUntil = gain(terminalNo);
//        if (audioSessionUntil == null) {
//            log.warn("获取不到页面链接的播放音频的请求");
//            return;
//        }
//        audioSessionUntil.push(rtpInfo);
//    }
//
//    /**
//     * 删除对应关系
//     * @param terminalNo
//     */
//    public static void del(String terminalNo) {
//        AudioSessionUntil remove = sessionAudioDtoMap.remove(terminalNo);
//        if (remove != null) {
//            remove.stop();
//        }
//    }
//
//    public static void delAllAudioCached(Session session) {
//        String terminalNo = MediaSocketChannel.del(session);
//        if (StringUtils.isNotBlank(terminalNo)) {
//            //RTP的缓存
//            NettyIntercomUntil.del(terminalNo);
//            //websocket的缓存
//            MediaSocketChannel.del(session);
//            //音频的缓存
//            del(terminalNo);
//        }
//    }
//}
